package com.intsig.airflow.web.test;

import com.intsig.airflow.web.model.DagEdge;
import com.intsig.airflow.web.model.DagEntity;
import com.intsig.airflow.web.model.DagNode;
import com.intsig.airflow.web.util.HashUtil;

import java.util.*;
import java.util.stream.Collectors;

/**
 * @author leo.jie (leojie1314@gmail.com)
 * @version 1.0
 * @organization 大猿小猿向前冲
 * @website https://www.jielongping.com
 * @date 2021/3/17 3:25 下午
 */
public class MockDagValue {
    public static List<List<String>> mockDagValue() {
        return Arrays.asList(Arrays.asList("qxb.daily_report_offline_data", "end", "behavior_dag_online"),
                Arrays.asList("behavior.cs_user_other_behavior_tag", "behavior.cs_gen_all_user_tag", "behavior_dag_online"),
                Arrays.asList("behavior.cs_user_other_behavior_tag", "end", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_search_behavior", "end", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_corpfeature_ts_corp_note_sensor", "cc_user_active_data_tomysql", "behavior_dag_online"),
                Arrays.asList("behavior.cs_device_uid_mapping_day", "end", "behavior_dag_online"),
                Arrays.asList("behavior.user_union_imei_with_time", "end", "behavior_dag_online"),
                Arrays.asList("cuhuo.ts_qxb_m_activation_push_all_cn", "end_0730", "behavior_dag_online"),
                Arrays.asList("external.send_qxb_project.daily", "end", "behavior_dag_online"),
                Arrays.asList("com_card.enterprise_common_search_condition", "com_card.enterprise_recommend_user_search", "behavior_dag_online"),
                Arrays.asList("behavior.cs_export_deviceid_detail", "end", "behavior_dag_online"),
                Arrays.asList("behavior.qxb_wakeup_30", "end_0730", "behavior_dag_online"),
                Arrays.asList("recmd.qxb_recmd_shitu", "recmd.trans_data", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_message_ts_message_sensor", "cc.send_wangan_cc_data", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_user_ts_user_cs_wx_profile_sensor", "cs.send_wangan_cs_data", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_user_ts_user_cs_wx_profile_sensor", "behavior.cs_user_person_backend_tag", "behavior_dag_online"),
                Arrays.asList("cc.push_wangan_data", "end", "behavior_dag_online"),
                Arrays.asList("user_tag.user_tag_cc_inc", "behavior.cc_user_tag_to_es", "behavior_dag_online"),
                Arrays.asList("trade.cs_all_order_pay_sensor", "cs.send_wangan_cs_data", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_sync_cc_ts_person_education_sensor", "person_user.user_edu_work_privacy", "behavior_dag_online"),
                Arrays.asList("app.cc_crash_email_push", "end", "behavior_dag_online"),
                Arrays.asList("behavior.cs_temp_action_info", "end", "behavior_dag_online"),
                Arrays.asList("trade.cs_all_order_pay_wide_summary_sensor", "behavior.cs_user_person_backend_tag", "behavior_dag_online"),
                Arrays.asList("behavior.cs_active_pro_unreg_user_to_mysql", "end_0730", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "behavior.cs_device_person_backend_tag", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_corpfeature_ts_corp_tag_management_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_du_db_enterprise_news_t_enterprise_news_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_pay_ts_purchase_cc_log_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_cs_0_ts_cs_appsflyer_record_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "mongo_etl.s_iQxb_orders_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_message_ts_message_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_sync_cc_ts_person_education_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_du_d_liudutui_t_resume_basic_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_sync_cc_ts_privacy_list_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "mongo_etl.s_iQxb_users_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_user_ts_user_cs_wx_profile_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "mongo_etl.s_iQxb_mpnewusertemps_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "mongo_etl.s_iQxb_vippurchaselogs_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_d_enterprise_change_t_push_items_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_corpfeature_ts_corp_note_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_cccorp_user_ts_corp_user_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_cs_account_ts_user_mobile_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl_hourly.s_du_iQxb_users_hourly_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_sync_cc_ts_person_work_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_cs_0_ts_cs_ad_list_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "behavior.qxb_active_data_active_event_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "trade.qxb_order_latest_source_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_bertadata_qxb_itmd_risk_ents_result_3m_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_d_monitor_t_user_monitor_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "person_ccp.qxb_contact_inc_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_cs_account_ts_user_email_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "trade.cs_all_order_pay_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_contacts_ts_contacts_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_cccorp_user_ts_corp_profile_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_cccorp_user_ts_corp_products_v2_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "user.profile2es_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_cccorp_user_ts_corp_activation_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_cs_account_ts_user_profile_sensor", "behavior_dag_online"),
                Arrays.asList("time.time_sensor_00_40", "sqoop_etl.s_db_user_ts_wx_profile_sv_sensor", "behavior_dag_online"),
                Arrays.asList("behavior.cs_user_person_tag", "behavior.cs_gen_all_user_tag", "behavior_dag_online"),
                Arrays.asList("behavior.cs_user_person_tag", "end", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_cs_0_ts_cs_ad_list_sensor", "cs.cs_ad_tag_action", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_cccorp_user_ts_corp_profile_sensor", "cc_user_active_data_tomysql", "behavior_dag_online"),
                Arrays.asList("hourly.check_cdbp_data.count_cdbp_streaming_avro_data_yesterday_22_sensor", "behavior.check_cdbp_data.compare_cdbp_streaming_avro_data", "behavior_dag_online"),
                Arrays.asList("analysis.qxb_enterprise_update_diff", "end_0730", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_contacts_ts_contacts_sensor", "cc.send_wangan_cc_data", "behavior_dag_online"),
                Arrays.asList("trade.qxb_order_latest_source_sensor", "user_tag.user_tag_qxb", "behavior_dag_online"),
                Arrays.asList("behavior.user_union_idfa_with_time", "end", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_cccorp_user_ts_corp_user_sensor", "cc_user_active_data_tomysql", "behavior_dag_online"),
                Arrays.asList("sqoop_etl_hourly.s_du_iQxb_users_hourly_sensor", "trade.qxb_order_latest_source_mini_program", "behavior_dag_online"),
                Arrays.asList("trade.qxb_order_latest_source_mini_program", "end", "behavior_dag_online"),
                Arrays.asList("user_tag.cc_no_active_user_push", "end_0730", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.user_search", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "zp_action.zp_key_action", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.user_union_imei_with_time", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.cs_guide_buy_success", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.qxb_clean_regular", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.qxb_spider_action", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "qxb_user.qxb_click_cme_user_push", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.cs_user_person_tag", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "cs.send_wangan_cs_data", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.user_union_idfa_with_time", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.cs_device_person_tag", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.user_union_device_with_time", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "qxb.daily_report_offline_data", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.qxb_user_viewed_cmp_recmd_data", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "user_tag.user_tag_qxb", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "qxb.company_and_person_event", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "trade.qxb_order_latest_source_mini_program", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "qxb.customer_list_recmd_statistics", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.cs_export_deviceid_detail", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.qxb_wakeup_60", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "app.cc_crash_email_push", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "user_tag.user_tag_zp", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.cc_advertisement_monitor_to_mysql", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "qxb.user_concern_set", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "zp_action.zp_email_action", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.cc_funnel_analysis_daily_run", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "user_tag.user_tag_cs_device_launch", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.cs_device_uid_mapping_day", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.qxb_wakeup_30", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.user_union_device", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.qxb_wakeup_t1t2_to_mysql", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "cc.cc_android_full_write_list", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "cc.send_wangan_cc_data", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.cs_active_pro_unreg_user_to_mysql", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "cc_user_active_data_tomysql", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "qxb_user.qxb_user_visit_eid_count", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "recmd.offline_data_update_sql", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.userid_last_ip_city", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.cs_shoot_action", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.cc_vip_trial_push_round_1th", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "analysis.qxb_enterprise_update_diff", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.cdbp_search_behavior", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.cs_export_deviceid", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "qxb.qxb_recmd_action", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "user_tag.user_tag_cc_device", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.all_product_buried_point_arrival_report", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "user_tag.user_tag_qxb_device", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "cs.cs_ad_tag_action", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "user_tag.user_tag_zp_device", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "external.send_qxb_project.daily", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "behavior.cs_action_all", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "user_tag.user_tag_cc_inc", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp_done_dummy", "user_tag.user_tag_cs_device", "behavior_dag_online"),
                Arrays.asList("recmd.qxb_fm_company_result", "end", "behavior_dag_online"),
                Arrays.asList("mongo_etl.s_iQxb_orders_sensor", "behavior.QxbVipTag", "behavior_dag_online"),
                Arrays.asList("mongo_etl.s_iQxb_orders_sensor", "trade.qxb_order_latest_source_mini_program", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_cs_account_ts_user_mobile_sensor", "user_tag.user_tag_cs", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_cs_account_ts_user_mobile_sensor", "behavior.cs_user_person_backend_tag", "behavior_dag_online"),
                Arrays.asList("hourly.cdbp_merge_file_add_partitions_yesterday_23_sensor", "behavior.cdbp_done_dummy", "behavior_dag_online"),
                Arrays.asList("behavior.cs_export_deviceid", "behavior.cs_gen_all_device_tag", "behavior_dag_online"),
                Arrays.asList("com_card.enterprise_recommend_user_search", "com_card.enterprise_recommend_qianke_list", "behavior_dag_online"),
                Arrays.asList("behavior.cs_shoot_action", "end", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_cccorp_user_ts_corp_activation_sensor", "cc_user_active_data_tomysql", "behavior_dag_online"),
                Arrays.asList("behavior.all_product_buried_point_arrival_report", "end_0730", "behavior_dag_online"),
                Arrays.asList("qxb.company_and_person_event", "qxb.online_recmd_prepare", "behavior_dag_online"),
                Arrays.asList("qxb.company_and_person_event", "qxb.strategy_2", "behavior_dag_online"),
                Arrays.asList("qxb.company_and_person_event", "qxb.strategy_1", "behavior_dag_online"),
                Arrays.asList("behavior.cs_action_all", "behavior.cs_device_other_behavior_tag", "behavior_dag_online"),
                Arrays.asList("behavior.cs_action_all", "end", "behavior_dag_online"),
                Arrays.asList("behavior.cs_action_all", "behavior.cs_user_other_behavior_tag", "behavior_dag_online"),
                Arrays.asList("behavior.qxb_wakeup_t1t2_to_mysql", "end_0730", "behavior_dag_online"),
                Arrays.asList("behavior.cs_ad_appsflyer_record", "end", "behavior_dag_online"),
                Arrays.asList("qxb.qxb_t3_web_arousal", "end_0730", "behavior_dag_online"),
                Arrays.asList("behavior.cs_device_person_tag", "behavior.cs_gen_all_device_tag", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_pay_ts_purchase_cc_log_sensor", "behavior.cc_vip_trial_push_round_2th", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_pay_ts_purchase_cc_log_sensor", "cc.send_wangan_cc_data", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_pay_ts_purchase_cc_log_sensor", "behavior.cc_vip_trial_push_round_1th", "behavior_dag_online"),
                Arrays.asList("behavior.user_union_device", "end", "behavior_dag_online"),
                Arrays.asList("mongo_etl.s_iQxb_mpnewusertemps_sensor", "trade.qxb_order_latest_source_mini_program", "behavior_dag_online"),
                Arrays.asList("user_tag.user_tag_cs_device_launch", "end_0730", "behavior_dag_online"),
                Arrays.asList("recmd.offline_data_update_sql", "end", "behavior_dag_online"),
                Arrays.asList("zp_action.zp_user_click_score", "end", "behavior_dag_online"),
                Arrays.asList("cs.cs_ad_tag_action", "end", "behavior_dag_online"),
                Arrays.asList("cs.cs_ad_tag_action", "cs.cs_ad_tag_action_push", "behavior_dag_online"),
                Arrays.asList("mongo_etl.s_iQxb_vippurchaselogs_sensor", "behavior.QxbVipTag", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_cs_account_ts_user_profile_sensor", "user_tag.user_tag_cs", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_cs_account_ts_user_profile_sensor", "behavior.cs_user_person_backend_tag", "behavior_dag_online"),
                Arrays.asList("enterprise_join_task_4", "enterprise.enterprise_user_info", "behavior_dag_online"),
                Arrays.asList("user_tag.user_tag_qxb", "behavior.QxbVipTag", "behavior_dag_online"),
                Arrays.asList("user_tag.user_tag_qxb", "recmd.qxb_recmd_shitu", "behavior_dag_online"),
                Arrays.asList("behavior.cc_vip_trial_push_round_2th", "end_0730", "behavior_dag_online"),
                Arrays.asList("cs.cs_wake_up_active_user_huawei", "end_0730", "behavior_dag_online"),
                Arrays.asList("behavior.cdbp2hive", "behavior.cdbp_done_dummy", "behavior_dag_online"),
                Arrays.asList("behavior.cc_user_tag_to_es", "end", "behavior_dag_online"),
                Arrays.asList("cs.cs_ad_tag_action_push", "end", "behavior_dag_online"),
                Arrays.asList("behavior.cs_gen_all_user_tag", "cs.send_wangan_cs_data", "behavior_dag_online"),
                Arrays.asList("behavior.cs_gen_all_user_tag", "behavior.cs_rentation_user", "behavior_dag_online"),
                Arrays.asList("qxb.user_concern_set", "qxb.company_list_recmd", "behavior_dag_online"),
                Arrays.asList("qxb.user_concern_set", "qxb.strategy_1", "behavior_dag_online"),
                Arrays.asList("qxb.user_concern_set", "qxb.strategy_2", "behavior_dag_online"),
                Arrays.asList("cs.cs_wake_up_active_user", "end_0730", "behavior_dag_online"),
                Arrays.asList("behavior.userid_last_ip_city", "behavior.userid_common_ip_city", "behavior_dag_online"),
                Arrays.asList("behavior.cs_gen_all_device_tag", "end_0730", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_cccorp_user_ts_corp_products_v2_sensor", "cc_user_active_data_tomysql", "behavior_dag_online"),
                Arrays.asList("person_user.user_edu_work_privacy", "end", "behavior_dag_online"),
                Arrays.asList("user_tag.user_tag_qxb_device", "end", "behavior_dag_online"),
                Arrays.asList("com_card.enterprise_recommend_base_data", "com_card.enterprise_common_search_condition", "behavior_dag_online"),
                Arrays.asList("behavior.userid_common_ip_city", "end", "behavior_dag_online"),
                Arrays.asList("cs.send_wangan_cs_data", "cs.push_wangan_data", "behavior_dag_online"),
                Arrays.asList("cs.send_wangan_cs_data", "cc_cs.wangan_bk_tk", "behavior_dag_online"),
                Arrays.asList("qxb.customer_list_recmd_statistics", "end", "behavior_dag_online"),
                Arrays.asList("behavior.qxb_fin_panorama_user", "end", "behavior_dag_online"),
                Arrays.asList("zp_action.zp_key_action", "zp_action.zp_user_click_score", "behavior_dag_online"),
                Arrays.asList("user_tag.user_tag_zp_device", "end", "behavior_dag_online"),
                Arrays.asList("behavior.user_search", "end", "behavior_dag_online"),
                Arrays.asList("behavior.qxb_user_viewed_cmp_recmd_data", "end_0730", "behavior_dag_online"),
                Arrays.asList("cuhuo.enterprise_news", "cuhuo.ts_qxb_m_activation_push_all_cn", "behavior_dag_online"),
                Arrays.asList("qxb_user.qxb_user_visit_eid_count", "end", "behavior_dag_online"),
                Arrays.asList("qxb.recmd_strategy_union", "qxb.hot_data_recmd", "behavior_dag_online"),
                Arrays.asList("behavior.qxb_clean_regular", "behavior.qxb_wakeup_60", "behavior_dag_online"),
                Arrays.asList("behavior.qxb_clean_regular", "behavior.qxb_wakeup_30", "behavior_dag_online"),
                Arrays.asList("behavior.qxb_clean_regular", "qxb.qxb_t3_web_arousal", "behavior_dag_online"),
                Arrays.asList("behavior.qxb_clean_regular", "cuhuo.ts_qxb_m_activation_push_all_cn", "behavior_dag_online"),
                Arrays.asList("behavior.qxb_clean_regular", "behavior.qxb_wakeup_t1t2_to_mysql", "behavior_dag_online"),
                Arrays.asList("cc.send_wangan_cc_data", "cc.push_wangan_data", "behavior_dag_online"),
                Arrays.asList("cc.send_wangan_cc_data", "cc_cs.wangan_bk_tk", "behavior_dag_online"),
                Arrays.asList("qxb.qxb_recmd_action", "end", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_du_db_enterprise_news_t_enterprise_news_sensor", "cuhuo.enterprise_news", "behavior_dag_online"),
                Arrays.asList("behavior.cc_advertisement_monitor_to_mysql", "end", "behavior_dag_online"),
                Arrays.asList("behavior.user_union_device_with_time", "user_tag.user_tag_qxb", "behavior_dag_online"),
                Arrays.asList("behavior.user_union_device_with_time", "end", "behavior_dag_online"),
                Arrays.asList("behavior.user_union_device_with_time", "user_tag.user_tag_qxb_device", "behavior_dag_online"),
                Arrays.asList("behavior.cs_user_person_backend_tag", "behavior.cs_gen_all_user_tag", "behavior_dag_online"),
                Arrays.asList("behavior.cs_user_person_backend_tag", "end", "behavior_dag_online"),
                Arrays.asList("enterprise.enterprise_user_info", "end_0730", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_corpfeature_ts_corp_tag_management_sensor", "cc_user_active_data_tomysql", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_user_ts_wx_profile_sv_sensor", "cc.send_wangan_cc_data", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_d_monitor_t_user_monitor_sensor", "recmd.qxb_recmd_shitu", "behavior_dag_online"),
                Arrays.asList("person_ccp.qxb_contact_inc_sensor", "recmd.offline_data_update_sql", "behavior_dag_online"),
                Arrays.asList("user_tag.user_tag_zp", "end", "behavior_dag_online"),
                Arrays.asList("behavior.check_cdbp_data.compare_cdbp_streaming_avro_data", "cdbp_check_failed_dummy", "behavior_dag_online"),
                Arrays.asList("behavior.check_cdbp_data.compare_cdbp_streaming_avro_data", "hourly.cdbp_merge_file_add_partitions_yesterday_23_sensor", "behavior_dag_online"),
                Arrays.asList("user_tag.user_tag_cs", "end", "behavior_dag_online"),
                Arrays.asList("user_tag.user_tag_cc_device", "end", "behavior_dag_online"),
                Arrays.asList("user_tag.user_tag_cc", "user_tag.cc_no_active_user_push", "behavior_dag_online"),
                Arrays.asList("user_tag.user_tag_cc", "user_tag.user_tag_cc_inc", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_du_d_liudutui_t_resume_basic_sensor", "person_user.zp_qixinbao_id_tran", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_du_d_liudutui_t_resume_basic_sensor", "person_user.user_edu_work_privacy", "behavior_dag_online"),
                Arrays.asList("person_user.zp_qixinbao_id_tran", "end", "behavior_dag_online"),
                Arrays.asList("com_card.enterprise_recommend_all_data", "end", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_bertadata_qxb_itmd_risk_ents_result_3m_sensor", "behavior.qxb_wakeup_60", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_bertadata_qxb_itmd_risk_ents_result_3m_sensor", "behavior.qxb_wakeup_30", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_bertadata_qxb_itmd_risk_ents_result_3m_sensor", "qxb.qxb_t3_web_arousal", "behavior_dag_online"),
                Arrays.asList("behavior.cs_rentation_user", "end_0730", "behavior_dag_online"),
                Arrays.asList("behavior.cs_device_other_behavior_tag", "behavior.cs_gen_all_device_tag", "behavior_dag_online"),
                Arrays.asList("behavior.cs_device_other_behavior_tag", "end", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_cs_account_ts_user_email_sensor", "user_tag.user_tag_cs", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_cs_account_ts_user_email_sensor", "behavior.cs_user_person_backend_tag", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_cs_0_ts_cs_appsflyer_record_sensor", "behavior.cs_ad_appsflyer_record", "behavior_dag_online"),
                Arrays.asList("behavior.qxb_wakeup_60", "end_0730", "behavior_dag_online"),
                Arrays.asList("behavior.cc_funnel_analysis_daily_run", "end", "behavior_dag_online"),
                Arrays.asList("end_0730", "end", "behavior_dag_online"),
                Arrays.asList("cs.push_wangan_data", "end", "behavior_dag_online"),
                Arrays.asList("behavior.QxbVipTag", "end", "behavior_dag_online"),
                Arrays.asList("mongo_etl.s_iQxb_users_sensor", "external.send_qxb_project.daily", "behavior_dag_online"),
                Arrays.asList("mongo_etl.s_iQxb_users_sensor", "behavior.qxb_wakeup_30", "behavior_dag_online"),
                Arrays.asList("mongo_etl.s_iQxb_users_sensor", "behavior.qxb_wakeup_t1t2_to_mysql", "behavior_dag_online"),
                Arrays.asList("mongo_etl.s_iQxb_users_sensor", "user_tag.user_tag_qxb", "behavior_dag_online"),
                Arrays.asList("mongo_etl.s_iQxb_users_sensor", "behavior.qxb_fin_panorama_user", "behavior_dag_online"),
                Arrays.asList("mongo_etl.s_iQxb_users_sensor", "behavior.qxb_wakeup_60", "behavior_dag_online"),
                Arrays.asList("mongo_etl.s_iQxb_users_sensor", "qxb.qxb_t3_web_arousal", "behavior_dag_online"),
                Arrays.asList("com_card.enterprise_recommend_primary_client", "com_card.enterprise_recommend_all_data", "behavior_dag_online"),
                Arrays.asList("user_tag.user_tag_cs_device", "behavior.cs_temp_action_info", "behavior_dag_online"),
                Arrays.asList("qxb_user.qxb_click_cme_user_push", "end", "behavior_dag_online"),
                Arrays.asList("qxb.company_list_recmd", "qxb.recmd_strategy_union", "behavior_dag_online"),
                Arrays.asList("cc.cc_android_full_write_list", "end_0730", "behavior_dag_online"),
                Arrays.asList("cc_user_active_data_tomysql", "end_0730", "behavior_dag_online"),
                Arrays.asList("behavior.cc_vip_trial_push_round_1th", "end_0730", "behavior_dag_online"),
                Arrays.asList("user.profile2es_sensor", "cc.send_wangan_cc_data", "behavior_dag_online"),
                Arrays.asList("user.profile2es_sensor", "user_tag.user_tag_cc", "behavior_dag_online"),
                Arrays.asList("behavior.cs_guide_buy_success", "end", "behavior_dag_online"),
                Arrays.asList("qxb.hot_data_recmd", "end", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_sync_cc_ts_privacy_list_sensor", "person_user.user_edu_work_privacy", "behavior_dag_online"),
                Arrays.asList("zp_action.zp_email_action", "end", "behavior_dag_online"),
                Arrays.asList("recmd.trans_data", "recmd.qxb_fm_company_result", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_d_enterprise_change_t_push_items_sensor", "qxb.daily_report_offline_data", "behavior_dag_online"),
                Arrays.asList("qxb.strategy_2", "qxb.recmd_strategy_union", "behavior_dag_online"),
                Arrays.asList("qxb.strategy_1", "qxb.recmd_strategy_union", "behavior_dag_online"),
                Arrays.asList("behavior.qxb_active_data_active_event_sensor", "behavior.QxbVipTag", "behavior_dag_online"),
                Arrays.asList("cdbp_check_failed_dummy", "camus.cloud_behavior_sensor", "behavior_dag_online"),
                Arrays.asList("camus.cloud_behavior_sensor", "behavior.cdbp2hive", "behavior_dag_online"),
                Arrays.asList("com_card.enterprise_recommend_qianke_list", "com_card.enterprise_recommend_primary_client", "behavior_dag_online"),
                Arrays.asList("sqoop_etl.s_db_sync_cc_ts_person_work_sensor", "person_user.user_edu_work_privacy", "behavior_dag_online"),
                Arrays.asList("behavior.cs_device_person_backend_tag", "behavior.cs_gen_all_device_tag", "behavior_dag_online"),
                Arrays.asList("behavior.cs_device_person_backend_tag", "end", "behavior_dag_online"),
                Arrays.asList("behavior.qxb_spider_action", "end", "behavior_dag_online"),
                Arrays.asList("cc_cs.wangan_bk_tk", "end", "behavior_dag_online"));
    }

    public static DagEntity mockDag() {
        DagEntity dagEntity = new DagEntity();
        dagEntity.setLabel("behavior_dag_online");

        Map<String, String> nodeStyle = new HashMap<>(1);
        nodeStyle.put("border", "1px solid greenYellow");

        Set<String> nodeStrSet = new HashSet<>();
        List<List<String>> values = mockDagValue();
        values.forEach(dags -> {
            nodeStrSet.add(dags.get(0));
            nodeStrSet.add(dags.get(1));
        });

        List<String> nodeStrList = new ArrayList<>(nodeStrSet);
        List<DagNode> nodes = new ArrayList<>();

        for (int i = 0; i < nodeStrList.size(); i++) {
            float posX = 100f + i + 5f;
            float posY = 120f + i + 5f;
            DagNode dagNode = new DagNode();
            dagNode.setId(HashUtil.toHash(nodeStrList.get(i)));
            dagNode.setName(nodeStrList.get(i));
            dagNode.setInPorts(new int[]{0});
            dagNode.setOutPorts(new int[]{0});
            dagNode.setPosX(posX);
            dagNode.setPosY(posY);
            dagNode.setType("Variable");
            dagNode.setWidth(180);
            dagNode.setHeight(30);
            dagNode.setNodeStyle(nodeStyle);
            dagNode.addNodeRightClickEvent("do some thing1", "eventOfDoSomeThingFirst");
            dagNode.addNodeRightClickEvent("do some thing2", "eventOfDoSomeThingSecond");
            nodes.add(dagNode);
        }

        List<DagEdge> edges = new ArrayList<>();

        for (int i = 0; i < values.size(); i++) {
            long id = i + 1;
            DagEdge edge = new DagEdge();
            edge.setId(id);
            edge.setSrcNodeId(HashUtil.toHash(values.get(i).get(0)));
            edge.setSrcOutputIdx(0);
            edge.setDstNodeId(HashUtil.toHash(values.get(i).get(1)));
            edge.setDstInputIdx(0);
            edges.add(edge);
        }
        dagEntity.addNodes(nodes);
        dagEntity.addEdges(edges);
        return dagEntity;
    }

    public static void main(String[] args) {


    }
}
